7cccf0ecee8b2d3ac654b73fb1b115de609524a0,ob1k-db/src/main/java/com/outbrain/ob1k/db/MySqlConnectionPool.java,MySqlConnectionPool,take,#,86

Before Change


  }

  private ComposableFuture<MySqlAsyncConnection> take() {
    final ComposableFuture<MySQLConnection> connFuture = ScalaFutureHelper.from(new ScalaFutureHelper.FutureProvider<MySQLConnection>() {
      @Override
      public Future<MySQLConnection> provide() {
        return _pool.take();
      }
    });

    return connFuture.continueOnSuccess(new SuccessHandler<MySQLConnection, MySqlAsyncConnection>() {
      @Override
      public MySqlAsyncConnection handle(final MySQLConnection result) {
        return new MySqlAsyncConnection(result);
      }
    });
  }

  private ComposableFuture<Boolean> giveBack(final MySqlAsyncConnection conn) {

After Change


  }

  private ComposableFuture<MySqlAsyncConnection> take() {
    final ComposableFuture<MySQLConnection> connFuture = ScalaFutureHelper.from(_pool::take);

    return connFuture.continueOnSuccess((SuccessHandler<MySQLConnection, MySqlAsyncConnection>) MySqlAsyncConnection::new);
  }

  private ComposableFuture<Boolean> giveBack(final MySqlAsyncConnection conn) {